# 3行代码定义一个异步任务 task.py
from celery import Celery

# 创建一个celery实例

# backend存储：把每一个异步运行的结果存储在什么地方
# 可以用redis，也可以是mysql，同样也可以用RPC消息队列，传到外面的消息队列里面存下来
# 这里使用redis

# broker：存储任务的系统，它的代理，里面也是一个消息队列，
# 把任务发到什么地方
app = Celery('tasks', backend='redis://127.0.0.1', broker='redis://127.0.0.1')

@app.task
def add(x, y):
    return x + y